package high.concurrent.config;

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.Properties;

/**
 * 使用kafka-cliend对topic与partition一些列操作的配置文件
 * 将之前test那些每个页面都写一遍的连接配置整合到了spring容器
 * 针对test下的, com.study.kafka.topic下的那些文件的连接方式
 */
@Configuration
public class KafkaConfig {

    @Bean
    public AdminClient initAdminClient(){
        Properties properties = new Properties();
        // 参数1： 固定写法，常量转换成字符串就是"bootstrap.servers",写这个字符串也行
        // 参数2： kafka所在的服务器ip:端口号， 多个集群用"," 隔开
        properties.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "xx.xxx.xx.xxx:9092");
        AdminClient adminClient = AdminClient.create(properties);
       return adminClient;
    }

}
